package com.juanpi.order.configuration.dao;

import com.juanpi.order.configuration.bean.KafkaConfigBean;
import com.juanpi.order.configuration.bean.KafkaTopic;

import java.util.List;

/**
 * @author xueqing
 *         Created on 2017/2/9.
 */
public interface KafkaConfigMapper {

    void saveKafkaConfig(KafkaConfigBean kafkaConfigBean);

    KafkaConfigBean queryKafkaConfigByKafkaName(String serviceName);

    void updateKafkaConfig(KafkaConfigBean kafkaConfigBean);

    List<KafkaConfigBean> listAllKafka();


}
